package backtype.storm.state;

import java.io.Serializable;
import java.util.Map;

import backtype.storm.task.TopologyContext;


public interface IStateSpout extends Serializable {
    void open(Map conf, TopologyContext context);


    void close();


    void nextTuple(StateSpoutOutputCollector collector);


    void synchronize(SynchronizeOutputCollector collector);
}
